package cn.wl._01rabbitmq_helloworld;

import cn.wl.ConnectionUtil;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;

public class Send {
    public static final String QUEUE_NAME_HELLO_WORLD = "my_rabbitmq_hello";

    public static void main(String[] args) throws Exception {
        //获取连接
        Connection connection = ConnectionUtil.getConnection();
        //获取通道
        Channel channel = connection.createChannel();
        //声明一个消息队列
        channel.queueDeclare(
                QUEUE_NAME_HELLO_WORLD, //队列名称
                true,            //队列持久化，关闭后打开还会存在
                false,          //一个队列占用一个连接
                false,         //服务器不使用该队列时删除它
                null            //队列的其他属性
        );
        //准备一条消息
        String message = "我是hello哈哈哈";
        //发送消息
        channel.basicPublish(
                "",             //使用默认的交换机
                QUEUE_NAME_HELLO_WORLD, //路由的key，可以看成是消息队列的名字，要将消息发送给哪个队列
                null,               //额外的参数
                message.getBytes()          //消息的内容
        );

    }
}
